/*
 ***************************************************************************************
 * All rights Reserved, Designed By RTF
 * @Title:  RocketMqProducerProperties.java   
 * @Package com.rtf.repair.mq.rocketmq.producer
 * @Description: rocketmq 生产者属性   
 * @author: 司福林
 * @date:   2020-10-17 16:34:16   
 * @version V1.0 
 * @Copyright: 2020 RTF. All rights reserved.
 * 注意：本内容仅限于公司内部使用，禁止外泄以及用于其他的商业目
 *  ---------------------------------------------------------------------------------- 
 * 文件修改记录
 *     文件版本：         修改人：             修改原因：
 ***************************************************************************************
 */
package com.rtf.framework.mq.rocketmq.producer;

import org.apache.rocketmq.common.MixAll;

import lombok.Data;

/**
 *  
 *
 * @ClassName:  RocketMqProducerProperties
 * @author: sfl
 * @date:   2020-10-17 16:34:16
 * @since:  v1.0
 */
@Data
public class RocketMqProducerProperties {

	/** nameserver 地址 */
	private String namesrvAddr;

	/** 实例名字 */
	private String instanceName = "DEFAULT";

	/** 拉去topic信息间隔 */
	private int pollNameServerInterval = 1000 * 30;

	/** 心跳间隔*/
	private int heartbeatBrokerInterval = 1000 * 30;

	/** 组名*/
	private String groupName = MixAll.DEFAULT_PRODUCER_GROUP;

	/** 发送消息超时时间*/
	private int sendMsgTimeout = 3000;

	/** 发送消息最大大小 */
	private int maxMessageSize = 1024 * 1024 * 4;

	/** 失败重试次数 */
	private int retryTimesWhenSendFailed = 2;

	/** 自定义队列选择器 配置实现{@link org.apache.rocketmq.client.producer.MessageQueueSelector}接口的类 如：xx.xx.xx.SelectQueueSelector*/
	private String queueSelector;
}
